11d5eef0dcdcaa9f0c79862d0efe54c593f8a4c9,src/org/jgroups/protocols/pbcast/NAKACK.java,NAKACK,handleMessage,#Message#NakAckHeader#,782

Before Change


                for(final Message msg_to_deliver: msgs) {

                    // discard OOB msg if it has already been delivered (http://jira.jboss.com/jira/browse/JGRP-379)
                    if(msg_to_deliver.isFlagSet(Message.OOB)) {
                        if(msg_to_deliver.setTransientFlagIfAbsent(Message.OOB_DELIVERED)) {
                            timer.execute(new Runnable() {
                                public void run() {
                                    up_prot.up(new Event(Event.MSG, msg_to_deliver));
                                }
                            });
                        }
                        continue;
                    }
                    num_regular_msgs_removed++;

                    // Changed by bela Jan 29 2003: not needed (see above)

After Change



                for(final Message msg_to_deliver: msgs) {
                    // discard OOB msg if it has already been delivered (http://jira.jboss.com/jira/browse/JGRP-379)
                    if(msg_to_deliver.isFlagSet(Message.OOB) && !msg_to_deliver.setTransientFlagIfAbsent(Message.OOB_DELIVERED))
                        continue;

                    //msg_to_deliver.removeHeader(getName()); // Changed by bela Jan 29 2003: not needed (see above)
                    try {
                        up_prot.up(new Event(Event.MSG, msg_to_deliver));